package com.ykx.message.dao;

import java.util.List;

import com.ykx.message.model.Tmessage;

public interface MessageDao {
	
	public void insert(Tmessage message) throws Exception;
	
	public void update(Tmessage message) throws Exception;
	
	public Tmessage getMessage(String messageId,String consumerQueue) throws Exception;
	
	public void remove(String messageId,String consumerQueue) throws Exception;
	
	public List<Tmessage> getMessageListTimeOut(String status,int batchSize) throws Exception;
}
